package cn.steam.foo.service;

import cn.steam.foo.message.Message;

import java.util.concurrent.ExecutionException;

/**
 * @author zhang jintao on 2022/05/18
 **/
public interface KafkaService {

    void send(Message message) throws ExecutionException, InterruptedException;

}
